google.golang.org/grpc/internal/transport.http2Server.activeStreams (field)
16 uses
google.golang.org/grpc/internal/transport (current package)
http2_server.go#L119: activeStreams map[uint32]*ServerStream
http2_server.go#L271: activeStreams: make(map[uint32]*ServerStream),
http2_server.go#L545: if uint32(len(t.activeStreams)) >= t.maxStreams {
http2_server.go#L590: t.activeStreams[streamID] = s
http2_server.go#L591: if len(t.activeStreams) == 1 {
http2_server.go#L654: s := t.activeStreams[se.StreamID]
http2_server.go#L707: if t.activeStreams == nil {
http2_server.go#L711: s, ok := t.activeStreams[f.Header().StreamID]
http2_server.go#L745: for _, s := range t.activeStreams {
http2_server.go#L904: ns := len(t.activeStreams)
http2_server.go#L1291: streams := t.activeStreams
http2_server.go#L1292: t.activeStreams = nil
http2_server.go#L1309: _, isActive := t.activeStreams[s.id]
http2_server.go#L1311: delete(t.activeStreams, s.id)
http2_server.go#L1312: if len(t.activeStreams) == 0 {
http2_server.go#L1400: if len(t.activeStreams) == 0 {
The pages are generated with Golds v0.8.4. (GOOS=linux GOARCH=amd64)